package com.lgCore.clientCocurrent;/**
 * Created by by on 2020/11/13 10:35
 */

import com.lgCore.controller.ClientBootstrap;
import com.lgCore.protoModel.ProtoMsg;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.concurrent.Callable;

/**
 * 任务异步执行
 *
 * @program: sxreader_rpc
 * @author: ligang
 * @create: 2020-11-13 10:35
 */
public class TaskCallable implements Callable<ProtoMsg.Message> {
    private static final Logger LOGGER = LoggerFactory.getLogger(TaskCallable.class);

    @Override
    public ProtoMsg.Message call() throws Exception {
        //处理心跳的数据
        try {
            ClientBootstrap.send();
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }
}
